package com.hong.concurrent.chapter13;

import com.hong.concurrent.chapter11.Context;

/**
 * @Author csh
 * @Description
 * @Date 2018/7/8 11:57
 */
public class ProducerAndConsumerClient {

    public static void main(String[] args) {
        final MessageQueue messageQueue = new MessageQueue();

        new ProducerThread(messageQueue,1).start();
        new ProducerThread(messageQueue,2).start();
        new ProducerThread(messageQueue,3).start();
        new ComSumerThread(messageQueue,1).start();
        new ComSumerThread(messageQueue,2).start();
    }
}
